package com.rico.queue.pulsar;

import com.rico.queue.common.TopicName;
import io.github.majusko.pulsar.producer.ProducerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class PulsarConfig {

    @Bean
    public ProducerFactory producerFactory() {
        return new ProducerFactory()
                .addProducer(TopicName.BATCH_SYNC_NFT_PROFILE, String.class);
    }
}